package com.source.flinkrpc;

import org.apache.flink.runtime.rpc.RpcGateway;

/**
 * 定义接口CustomGateway
 * Flink内部所有的rpc通信接口的定义都要继承或者实现RpcGateway
 * 里面定义了一系列远程调用的方法
 */
public interface CustomGateway extends RpcGateway {

     String getName();
}
